/**
 * 构建TCP客户端
 */

/* 引入net模块 */
var net = require("net");
const WebSocket = require('ws')
// var ws = require("nodejs-websocket");
const WebSocketServer = WebSocket.Server
const wss = new WebSocketServer({ port: 9000 })
/* 创建TCP客户端 */

wss.on('connection', (ws, req) => {
    console.log('connection')

    // var int = setInterval(function f() {
    //     send(data)
    // }, 1000)
    // 接收客户端信息并把信息返回发送
    // ws.on('message', (message) => {
    //     ws.send(message, (err) => { // send 方法的第二个参数是一个错误回调函数
    //         if (err) {
    //             console.log(`[SERVER] error: ${err}`);
    //         }
    //     })
    // })
})
var client = net.Socket();

/* 设置连接的服务器 */
client.connect(2019, '192.168.0.121', function (data) {
    console.log("connect the server");
    /* 向服务器发送数据 */
    client.write("message from client");
})

/* 监听服务器传来的data数据 */
client.on("data", function (data) {
    // if (user) {
    console.log(data)
    // console.log(data)
    wss.clients.forEach(function each(client) {
        client.send(data)
    })
    // }
    // console.log("the data of server is " + data.toString());
})

/* 监听end事件 */
client.on("end", function () {
    console.log("data end");
})